package com.bangcommunity.bbframe.mq.consumer;

import java.io.Serializable;

/**
 * Created by tanghc on 17/2/4.
 */
public interface IQtMsgProcessor<T extends Serializable> {
    void onConsume(String msgId, T o);
}
